package com.xq.operation;

import com.xq.utils.CustomSerializer;
import org.I0Itec.zkclient.ZkClient;
import org.apache.zookeeper.CreateMode;

/**
 * 单机版连接ZK，字符串序列化
 * @author 卡布奇诺
 */
public class TestZkServerString {
    /**
     * ZK连接URL
     */
    private static final String SERVER_IP = "192.168.2.120:2190";

    /**
     * zk客户端对象
     */
    private static ZkClient zkClient = null;

    static {
        // 初始化zk客户端对象
        zkClient = new ZkClient(SERVER_IP,10000,10000,new CustomSerializer());
    }

    public static void main( String[] args ) {
        /**
         *  1、创建节点
         *  参数1：路径
         *  参数2：数据
         *  参数3：节点类型，持久的
         */
        zkClient.create("/data_str","你好", CreateMode.PERSISTENT);
        // 2、查询
        Object data = zkClient.readData("/data_str");
        System.out.println(data);
        System.out.println("操作成功ZkClient");
    }
}
